from dagster import get_dagster_logger, job, op

logger = get_dagster_logger()


@op
def op_function():
    logger.info('op')
    return 'op'


@job
def dagster_job():
    logger.info('job')
    op_result = op_function()
    logger.info(f"op_result={op_result}")


if __name__ == '__main__':
    result = dagster_job.execute_in_process(
        run_config={"loggers": {"console": {"config": {"log_level": "info"}}}}
    )
